package org.tao.lightningmq.nameserver.test;

import com.alibaba.fastjson2.JSON;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import org.tao.lightningmq.common.tcp.TcpMsg;

/**
 * @Author lht
 * @date 2025/1/8 - 16:15
 * @description:
 */
public class NameServerRespChannelHandler extends SimpleChannelInboundHandler<TcpMsg> {
    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, TcpMsg tcpMsg) throws Exception {
        System.out.println("resp:" + JSON.toJSONString(tcpMsg));
    }
}
